package com.qiaofang.applet.service.property.repository;

import com.qiaofang.applet.service.property.domain.SyncDataQueue;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.mongodb.repository.MongoRepository;

public interface SyncDataQueueRepository extends MongoRepository<SyncDataQueue, String> {
        Page<SyncDataQueue> findByProcessingStatusAndDataTypeOrderByUpdateTimeAsc(String processingStatus, String dataType, Pageable pageable);
        int countByProcessingStatusAndDataType(String processingStatus, String dataType);
        int deleteByProcessingStatusAndDataType(String processingStatus, String dataType);
}
